package com.whynot.frame.manythread.flowline;

import com.whynot.frame.manythread.flowline.entities.Msg;

public class Client {

	public static void main(String[] args) {
		/**
		 * 宪哥流行线程都开启，各执行各的
		 */
		new Thread( new Plus()).start();
		new Thread( new Multiply()).start();
		new Thread( new Div()).start();
		
		for(int i = 0 ; i<= 10;i++){
			for(int j = 0 ; j <= 5; j++){
				Msg msg = new Msg();
				msg.i = i;
				msg.j = j;
				//Plus流行线程开启
				Plus.qDeque.add(msg);
			}
		}
	}
}
